package com.qfjy.controller.example2;


import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.servlet.http.HttpServletRequest;

@Controller
@RequestMapping("weather")
@Slf4j
public class WeatherController {

    @Autowired
    private AmqpTemplate amqpTemplate;
    /**
     *  #TODO 气象局 生产最新天气预报情况
     */
    @GetMapping("sendWeatherInfo")
    @ResponseBody
    public String sendWeatherInfo(HttpServletRequest request){
        //天气信息情况  根据后台气象局的数据查询得到新的气象结果
        String city=request.getParameter("city");
        String msg="最新天气 晴 20度，微风==>"+city;

        log.info("最新气象局的天气信息：{}",msg);

        //很多大的电商平台 获得最新的天气预报：  京东、淘宝、百度、新浪、腾讯..........几十万个。  多线程---》 MQ解决
        /**
         * String exchange, String routingKey, Object object
         * @param1 :exchange 定义交换机名称
         * @param2: 路由key
         * @param3: object数据传输的载体（二进制）
         */
        amqpTemplate.convertAndSend("weatherFanoutExchange",null,msg);

        return "天气最新信息 发布成功";
    }

}
